//package com.ruoyi.ahs.scheduler;
//
//import com.ruoyi.ahs.cache.AhsCache;
//import com.ruoyi.ahs.service.IRushService;
//import com.ruoyi.ahs.util.RushTaskDto;
//import com.ruoyi.ahs.util.WeChatBotMessageSender;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.stereotype.Component;
//
//import javax.annotation.Resource;
//import java.time.LocalDateTime;
//import java.util.List;
//
///**
// * 抢购任务调度
// *
// * @author 辛凤文
// * @since 1.0
// */
//@Slf4j
//@Component("rush")
//public class RushTaskScheduler {
//
//    @Resource
//    private IRushService rushTaskService;
//
//    @Deprecated
//    public void run() {
//        try {
//            log.info("---------开始执行抢购任务 当前时间：{}------------------", LocalDateTime.now());
//            List<RushTaskDto> tasks = AhsCache.getRushTaskCache();
//            if (org.springframework.util.CollectionUtils.isEmpty(tasks)) {
//                return;
//            }
//            tasks.forEach(task -> {
//                Long frequency = task.getFrequency();
//                for (long i = 0L; i < frequency; i++) {
//                    rushTaskService.rushGoods(task);
//                }
//            });
//            log.info("---------结束执行抢购任务 当前时间：{}------------------", LocalDateTime.now());
//        } catch (Exception e) {
//            WeChatBotMessageSender.sendMessage("系统异常请联系管理员");
//            e.printStackTrace();
//        }
//
//    }
//}
